package com.pad.dpscn.daag.sdk.core.async;

import java.util.concurrent.ConcurrentLinkedQueue;

import org.springframework.stereotype.Service;

import com.pad.dpscn.daag.sdk.common.message.MqMessage;

/**
 * 
 * com.pad.dpscn.daag.sdk.core.async  
 *  
 * <p>  
 * Description: 用于异步查询数据库并发送消息
 * </p>  
 *  
 * @author yangdezhao
 * @since 2024年3月11日  
 * @version 1.0
 */
@Service
public interface AsyncQueryDbAndSendMsgService {
	void asyncQueryDbAndSendMsg( ConcurrentLinkedQueue<MqMessage> dataQueue);
}
